package com.siashan.unipay4j.ali.pay;

import com.alipay.api.AlipayApiException;
import com.siashan.unipay4j.ali.AbstractAliPay;
import com.siashan.unipay4j.core.IPayConfig;
import com.siashan.unipay4j.core.pay.IPayment;
import com.siashan.unipay4j.core.pay.PayModel;
import com.siashan.unipay4j.core.Result;
import lombok.extern.slf4j.Slf4j;

import java.util.HashMap;
import java.util.Map;

/**
 * 支付宝支付抽象类
 *
 * @author siashan
 * @since v1.0.1
 **/
@Slf4j
public abstract class AliPay extends AbstractAliPay implements IPayment {


    public AliPay() {
        initClient();
    }

    public AliPay(IPayConfig payConfig) {
        super(payConfig);
    }


    /**
     * 方法描述: 统一下单接口
     *
     * @param model 下单参数封装
     * @return 下单结果
     */
    @Override
    public final Result pay(PayModel model) {
        String outTransNo = model.getOutTradeNo();
        String tradeType = getTradeType().getValue();
        log.info("AliPay::{}=>订单{} 支付请求到达", tradeType, outTransNo);
        // 初始化客户端
        initClient();
        // 下单请求
        Result payResult = null;
        try {
            payResult = executePay(wrapperCommonRequestData(model));
            if (log.isDebugEnabled()) {
                log.debug("AliPay::{}=>订单{} 下单返回报文{}", tradeType, outTransNo, payResult.getData());
            }
            if (payResult.isReturnSuccess()) {
                log.info("AliPay::{}=>订单{} 下单成功", tradeType, outTransNo);
            } else {
                log.info("AliPay::{}=>订单{} 下单失败,错误代码{},错误原因{}", tradeType, outTransNo, payResult.getErrCode(), payResult.getErrMsg());
            }
        } catch (AlipayApiException e) {
            log.warn("AliPay::{}=>订单{} 下单时发生异常", tradeType, outTransNo, e);
            payResult = Result.exception();
        }
        return payResult;
    }


    /**
     * 方法描述: 封装通用请求参数
     *
     * @param model 支付请求参数
     * @return 请求参数
     */
    private Map<String, Object> wrapperCommonRequestData(PayModel model) {
        Map<String, Object> params = new HashMap<>(4);
        // 平台订单号
        params.put("out_trade_no", model.getOutTradeNo());
        //付款金额，必填
        params.put("total_amount", String.valueOf(model.getPrice().doubleValue()));
        //订单名称，必填
        params.put("subject", model.getSubject());
        //商品描述，可空
        params.put("body", model.getBody());
        if (needBuyerId()) {
            // 新商户建议使用buyer_open_id替代该字段。对于新商户，buyer_id字段未来计划逐步回收，存量商户可继续使用。如使用buyer_open_id，请确认 应用-开发配置-openid配置管理 已启用
            // @see <a href="https://open.alipay.com/api/detail?code=I1140300001000013424&index=1">统一收单交易创建接口，业务请求参数</a>
            if (payConfig.isUseOpenId()) {
                params.put("buyer_open_id", model.getOpenid());
            } else {
                params.put("buyer_id", model.getOpenid());
            }

        }
        return params;
    }


    /**
     * 方法描述: 执行支付请求
     *
     * @param params 支付请求参数
     * @return 支付结果
     */
    public abstract Result executePay(Map<String, Object> params) throws AlipayApiException;

    /**
     * 方法描述: 获取交易类型
     *
     * @return 交易类型
     */
    public abstract AliTradeTypeEnum getTradeType();

    /**
     * 是否需要buyerId参数
     *
     * @return
     */
    public abstract boolean needBuyerId();
}
